package org.idea.qiyu.framework.rocketmq.config.consumer;

import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;

/**
 * 消费者统一实现该接口
 *
 * @Author linhao
 * @Date created in 5:54 下午 2021/7/2
 */
public interface IConcurrentlyConsumer<T> {

    /**
     * 消费处理逻辑
     *
     * @param msg
     * @return
     */
    ConsumeConcurrentlyStatus consume(T msg);
}
